package com.ymt.reliable.message.exceptionretry.service;

import com.ymt.reliable.message.exceptionretry.task.Task;

/**
 * 消息表中尚未死亡的消息重试服务接口
 */
public interface MessageExceptionRetryService {
    void addTask(Task task);

    Integer queueSize();
}
